package org.rency.common.mq.handler;

import org.rency.common.mq.request.MQRequest;

/**
 * 消息处理器
 * 消息监听器收到消息后，最终交给消息处理器进行处理
 * @author: user_rcy@163.com
 * </br>Created on 2016年4月8日
 * @version: V1.0.0
 * @since JDK 1.8
 */
public interface MessageHandler {

	/**
	 * 处理消息内容
	 * </br>Created on 2016年4月8日
	 * @param message
	 */
	public void handler(Object request);
	
	/**
	 * 处理消息内容
	 * @param request	消息内容
	 * @throws MessageHandleException
	 */
	public void handleMessage(Object request) throws Exception;
	
	/**
	 * 将消息内容转换为MQRequest
	 * </br>Created on 2016年4月8日
	 * @param request
	 * @return
	 */
    public MQRequest convertToMQRequest(Object request);
}